package com.ezops.poc.routing;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import com.ezops.poc.aggregation.EzopsAggregationStrategy;
import com.ezops.poc.bo.ot.ClientOTEquityModel;

@Component(value="loggingProcessor")
public class LoggingProcessor implements Processor {
	private static final Logger LOGGER = LoggerFactory
			.getLogger(EzopsAggregationStrategy.class);


	public void process(Exchange exchange) throws Exception {
		System.err.println("\n Received Order: "
				+ exchange.getIn().getBody(String.class));
		LOGGER.debug("\n Received Order: "
				+ exchange.getIn().getBody(String.class));
		//System.err.println("333333 -"+exchange.getIn().getHeader(Exchange.FILE_NAME_CONSUMED)); 

	
		//exchange.getIn().setBody(new CalypsoUploadDocument());

	}
}
